5f561708916e302e01b0879696f6db137061ad43,src/main/java/com/steelbridgelabs/oss/neo4j/structure/Neo4JSession.java,Neo4JSession,edges,#Object[]#,370
Before Change
return combine(identifiers.stream().filter(edges::containsKey).map(id -> (Edge)edges.get(id)), Stream.empty());
}
// vertex match predicates
String outVertexPredicate = partition.vertexMatchPredicate("n");
String inVertexPredicate = partition.vertexMatchPredicate("m");
// cypher statement for all edges in database
Statement statement = new Statement("MATCH " + generateVertexMatchPattern("n") + "-[r]->" + generateVertexMatchPattern("m") + (outVertexPredicate != null && inVertexPredicate != null ? " WHERE " + outVertexPredicate + " AND " + inVertexPredicate : "") + " RETURN n, r, m");
// execute statement
StatementResult result = executeStatement(statement);
// find edges
After Change
return combine(identifiers.stream().filter(edges::containsKey).map(id -> (Edge)edges.get(id)), Stream.empty());
}
// cypher statement for all edges in database
Statement statement = new Statement("MATCH " + generateVertexMatchPattern("n") + "-[r]->" + generateVertexMatchPattern("m") + (partition.usesMatchPredicate() ? " WHERE " + partition.vertexMatchPredicate("n") + " AND " + partition.vertexMatchPredicate("m") : "") + " RETURN n, r, m");
// execute statement
StatementResult result = executeStatement(statement);
// find edges